package com.xhx.stream.stream;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * 生产者通道接口
 * 
 * @author xhx
 */
public interface CustomSourceChannel {
	String FACE_OUTPUT = "face_output";
	String HUMAN_OUTPUT = "human_output";
	String VEHICLE_OUTPUT = "vehicle_output";
	String LOG_OUTPUT = "log_output";

	@Output(LOG_OUTPUT)
	MessageChannel logOutput();

	@Output(FACE_OUTPUT)
	MessageChannel faceOutput();

	@Output(HUMAN_OUTPUT)
	MessageChannel humanOutput();

	@Output(VEHICLE_OUTPUT)
	MessageChannel vehicleOutput();
}